# 先导入pymysql
import pymysql


# 封装
# 先定义一个类名
class DB:
    def __init__(self):
        #建立连接         #连接   本机地址             端口号  用户名       密码            数据库名 编码格式     以字典的形式返回
        self.coon=pymysql.connect(host='localhost',port=3306,user='root',password='root',db='workf1',charset='utf8',cursorclass=pymysql.cursors.DictCursor)
        #建立游标
        self.cousor=self.coon.cursor()
    #增、删、改
    def insert(self,sql):
        #调用游标执行sql语句
        self.cousor.execute(sql)
        #调用连接将数据提交到数据库
        self.coon.commit()
    
    #查询一条数据
    def find(self,sql):
        self.cousor.execute(sql)
        res=self.cousor.fetchone()
        return res


    #查询全部数据
    def findall(self,sql):
        #调用游标提交数据
        self.cousor.execute(sql)
        #调用游标查一条数据
        res=self.cousor.fetchall()
        #返回查询到的数据
        return res

    #关闭
    def close(self):
        #关闭游标
        self.cousor.close()
        #关闭连接
        self.coon.close()

db1=DB()